9cd192b43943cb1bd622e21152fd4397c81975da,enterprise/src/main/java/org/neo4j/kernel/impl/transaction/xaframework/LogIoUtils.java,LogIoUtils,readTxOnePhaseCommitEntry,#ByteBuffer#ReadableByteChannel#,137
Before Change
private static LogEntry.OnePhaseCommit readTxOnePhaseCommitEntry( ByteBuffer buf,
ReadableByteChannel channel ) throws IOException
{
buf.clear();
buf.limit( 12 );
if ( channel.read( buf ) != buf.limit() )
{
return null;
}
buf.flip();
int identifier = buf.getInt();
long txId = buf.getLong();
return new LogEntry.OnePhaseCommit( identifier, txId );
}
private static LogEntry.Done readTxDoneEntry( ByteBuffer buf,
After Change
return new LogEntry.Prepare( readNextInt( buf, channel ) );
}
private static LogEntry.OnePhaseCommit readTxOnePhaseCommitEntry( ByteBuffer buf,
ReadableByteChannel channel ) throws IOException, ReadPastEndException
{
return new LogEntry.OnePhaseCommit( readNextInt( buf, channel ),
readNextLong( buf, channel ) );
}
private static LogEntry.Done readTxDoneEntry( ByteBuffer buf,